const { connection } = require("../db/index");
//创建单一连接,开启事务锁保证多个sql操作同步完成或失败回滚
function connectionQuery(sql) {
  // console.log(sql);
  return new Promise((reslove, reject) => {
    try {
      connection.connect((err) => {
        if (err) {
          reject(err);
        }
        console.log("已连接到数据库");
        connection.query(sql, (err, results) => {
          if (err) {
            reject(err);
          }
          connection.end();
          reslove(results);
        });
      });
    } catch (error) {
      reject(error);
    }
  });
}
module.exports = connectionQuery;
